home *** CD-ROM | disk | FTP | other *** search
/ Java Programmer's Toolkit / Java Programmer's Toolkit.iso / hotjava3 / hotjava3.exe / hotjava / classsrc / java / io / PipedOutputStream.java < prev    next >
Encoding:
Java Source  |  1995-08-11  |  2.6 KB  |  93 lines
  1. /*
  2.  * @(#)PipedOutputStream.java    1.2 95/01/31 James Gosling
  3.  *
  4.  * Copyright (c) 1994 Sun Microsystems, Inc. All Rights Reserved.
  5.  *
  6.  * Permission to use, copy, modify, and distribute this software
  7.  * and its documentation for NON-COMMERCIAL purposes and without
  8.  * fee is hereby granted provided that this copyright notice
  9.  * appears in all copies. Please refer to the file "copyright.html"
  10.  * for further important copyright and licensing information.
  11.  *
  12.  * SUN MAKES NO REPRESENTATIONS OR WARRANTIES ABOUT THE SUITABILITY OF
  13.  * THE SOFTWARE, EITHER EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED
  14.  * TO THE IMPLIED WARRANTIES OF MERCHANTABILITY, FITNESS FOR A
  15.  * PARTICULAR PURPOSE, OR NON-INFRINGEMENT. SUN SHALL NOT BE LIABLE FOR
  16.  * ANY DAMAGES SUFFERED BY LICENSEE AS A RESULT OF USING, MODIFYING OR
  17.  * DISTRIBUTING THIS SOFTWARE OR ITS DERIVATIVES.
  18.  */
  19.  
  20. package java.io;
  21. import java.io.Piped;
  22.  
  23. /**
  24.  * Piped output stream, must be connected to a PipedInputStream.
  25.  * A thread reading from a PipedInputStream recieves data from
  26.  * a thread writing to the PipedOutputStream it is connected to.
  27.  * @see    PipedInputStream
  28.  * @version     95/01/31
  29.  * @author    James Gosling
  30.  */
  31. public
  32. class PipedOutputStream extends OutputStream {
  33.     private PipedInputStream sink;
  34.  
  35.     /**
  36.      * Creates an output file connected to a PipedInputStream
  37.      * @param snk    The InputStream to connect to.
  38.      */
  39.     public PipedOutputStream(PipedInputStream snk) {
  40.     connect(snk);
  41.     }
  42.     
  43.     /**
  44.      * Creates an output file that isn't connected to anything (yet).
  45.      * It must be connected before being used.
  46.      */
  47.     public PipedOutputStream() {
  48.     }
  49.     
  50.     /**
  51.      * Connect this output stream to a reciever.
  52.      * @param snk    The InputStream to connect to.
  53.      */
  54.     public void connect(PipedInputStream snk) {
  55.     sink = snk;
  56.     snk.closed = false;
  57.     snk.in = -1;
  58.     snk.out = 0;
  59.     }
  60.  
  61.     /**
  62.      * Write a byte. Will block until the byte is actually
  63.      * written.
  64.      * @exception IOException i/o error occurred
  65.      */
  66.     public void write(int b) {
  67.     sink.recieve(b);
  68.     }
  69.  
  70.     /**
  71.      * Writes a sub array of bytes.
  72.      * @param b    the data to be written
  73.      * @param off    the start offset in the data
  74.      * @param len    the number of bytes that are written
  75.      * @exception IOException i/o error occurred
  76.      */
  77.     public void write(byte b[], int off, int len) {
  78.     sink.recieve(b, off, len);
  79.     }
  80.  
  81.     /**
  82.      * Closes the stream. This method must be called
  83.      * to release any resources associated with the
  84.      * stream.
  85.      * @exception IOException i/o error occurred
  86.      */
  87.     public void close() {
  88.     if (sink != null) {
  89.         sink.recievedLast();
  90.     }
  91.     }
  92. }
  93.